package com.yuven.baselib.component.task;

import io.reactivex.disposables.Disposable;

/**
 * 能跟踪Rx任务，统一管理
 */
public interface IRxTaskRecorder {

    /**
     * 每个Rx任务，要注册自己的取消订阅引用
     *
     * @param disposable
     */
    void subscribeSubject(Disposable disposable);

    /**
     * 取消订阅所有已注册的Rx任务
     */
    void unSubscribeAllSubjects();
}
